package com.starsky.common.kafka.service;

import org.springframework.stereotype.Component;

/**
 * kafka消费者测试
 */
@Component
public class TestConsumer {

//    @KafkaListener(topics = "test_topic")
//    public void listen (ConsumerRecord<?, ?> record) throws Exception {
//        System.out.printf("topic = %s, offset = %d, value = %s \n", record.topic(), record.offset(), record.value());
//    }
}
